package com.burgess.net;

import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.Session;

/**
 * 创建人    BurgessLee
 * 创建时间   2020/5/28
 * 描述
 */
public class MyMessageSend {

    @Test
    public void test(){
        ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext("spring-bean.xml");
        //获取消息发送模板工具
        JmsTemplate jt=(JmsTemplate)ctx.getBean("jmsTemplate");
        //获取用于发送消息的队列
        Queue que1=(Queue)ctx.getBean("queue01");
        //向对应队列发送消息
        jt.send(que1, new MessageCreator() {
            @Override
            public Message createMessage(Session session) throws JMSException {
                return session.createTextMessage("Spring msg=====消息发送");
            }
        });
    }

}
